package com.shanks.framework.mq.demo.builder;

import com.shanks.framework.mq.model.MessageRecordPO;

import java.util.UUID;

public class MessageBuilder {
    public static MessageRecordPO buildMessage(String topic , String tag , String messageJson ){
        MessageRecordPO messageRecordPO = new MessageRecordPO();
        messageRecordPO.setMessageTopic(topic);
        messageRecordPO.setMessageTag(tag);
        messageRecordPO.setMessageJson(messageJson);
        messageRecordPO.setBizUuid(UUID.randomUUID().toString());
        messageRecordPO.setBizType("TEST");
        return messageRecordPO;
    }
}
